from airflow.models import DagRun
from airflow.utils import dates
from airflow.utils.session import create_session

if __name__ == '__main__':
    with create_session() as session:
        dt= dates.from_milliseconds(1679941800000)
        dr = DagRun.get_dag_run(session=session,dag_id='dag-102743',execution_date=dt)
        print(dr)